from datetime import timedelta
from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor
from jms.time_sensor.time_after_07_00 import  time_after_07_00

jms_dim__dim_dependent_06 = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dim__dim_dependent_06",
    filepath='/dw/hive/jms_dim.db/external/dim_dependent/dt={{ execution_date | date_add(1) | cst_ds }}-06/dep=shipment',
    execution_timeout=timedelta(hours=2),
    email=['rongguangfan@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=1,
)
jms_dim__dim_dependent_06 << time_after_07_00
